package com.ss.utils;
import java.sql.Connection;
        import java.sql.DriverManager;
        import java.sql.ResultSet;
        import java.sql.Statement;

public class HiveClientTools {
    // Hive JDBC连接的URL模板
    private static String driverName = "org.apache.hive.jdbc.HiveDriver";

    // Hive服务器的JDBC URL
    // 请根据实际情况修改Hive服务器地址、端口和数据库名称
    private static String connectionUrl = "jdbc:hive2://<hive-server>:<port>/<database>";

    // Hive用户名和密码（如果Hive配置了认证）
    private static String user = "";
    private static String password = "";

    public static void main(String[] args) throws Exception {
        // 注册JDBC驱动
        Class.forName(driverName);

        // 获取连接
        Connection con = DriverManager.getConnection(connectionUrl, user, password);

        // 创建Statement对象
        Statement stmt = con.createStatement();

        // 执行SQL查询
        String sql = "SELECT * FROM your_table_name";
        ResultSet res = stmt.executeQuery(sql);

        // 处理结果集
        while (res.next()) {
            // 假设表中有两个字段：id 和 name
            int id = res.getInt("id");
            String name = res.getString("name");
            // 打印结果
            System.out.print("ID: " + id);
            System.out.println(", Name: " + name);
        }

        // 关闭资源
        res.close();
        stmt.close();
        con.close();
    }
}